7810361d2e5a2f236967b3208053ec80b0e5885a,streams-contrib/streams-amazon-aws/streams-persist-kinesis/src/main/java/org/apache/streams/amazon/kinesis/KinesisPersistReader.java,KinesisPersistReader,prepare,#Object#,155

Before Change


      clientConfig.setProtocol(Protocol.valueOf(config.getProtocol().toString()));

      this.client = new AmazonKinesisClient(credentials, clientConfig);
      if (!Strings.isNullOrEmpty(config.getRegion()))
        this.client.setRegion(Region.getRegion(Regions.fromName(config.getRegion())));
    }
    streamNames = this.config.getStreams();

After Change


      clientConfig.setProtocol(Protocol.valueOf(config.getProtocol().toString()));

      this.client = new AmazonKinesisClient(credentials, clientConfig);
      if (StringUtils.isNotEmpty(config.getRegion()))
        this.client.setRegion(Region.getRegion(Regions.fromName(config.getRegion())));
    }
    streamNames = this.config.getStreams();